package top.codetheory.thread;

//import org.springframework.context.annotation.Bean;

//
//@Configuration
//public class ThreadPoolConfig {
//    @Bean
//    public ExecutorService executorService(){
//        AtomicInteger atomicInteger = new AtomicInteger(1);  // 原子的Integer, 下面getAndIncrement() 会让这个值自增1, 用到了cas
//        LinkedBlockingQueue<Runnable> linkedBlockingQueue = new LinkedBlockingQueue<>();
//        // 核心线程  最大线程  急救线程的生存时间  时间单位  阻塞队列  线程工厂  拒绝策略
//        return new ThreadPoolExecutor(
//                2,
//                3,
//                1000,
//                TimeUnit.MILLISECONDS,
//                linkedBlockingQueue,
//                r -> new Thread(r, "myThread--" + atomicInteger.getAndIncrement()),
//                new ThreadPoolExecutor.AbortPolicy()
//
//        );
//    }
//}

